#! /bin/bash
HIVE_HOME=/usr/bin/hive


if [[ $1 == "" ]];then
   TD_DATE=`date -d '1 days ago' "+%Y-%m-%d"`
else
   TD_DATE=$1
fi


${HIVE_HOME} -S -e "


------------------因为采用了动态分区插入技术 因此需要设置相关参数---------------
--分区
SET hive.exec.dynamic.partition=true;--开启动态分区
SET hive.exec.dynamic.partition.mode=nonstrict;--开启非严格模式
set hive.exec.max.dynamic.partitions.pernode=10000; --设置每个节点最大分区数
set hive.exec.max.dynamic.partitions=100000; --设置总共的最大分区数
set hive.exec.max.created.files=150000;--设置可以创建的最大文件，默认100
--hive压缩
set hive.exec.compress.intermediate=true;
set hive.exec.compress.output=true;
--写入时压缩生效
set hive.exec.orc.compression.strategy=COMPRESSION;

--customer_appeal 线索申诉信息表
--循环增量导入
INSERT overwrite TABLE zx_dwd.dwd_dim_customer_appeal_apply PARTITION(dt)
select
 *
 from zx_ods.ods_customer_appeal_apply
 where dt='${TD_DATE}';

  --customer_relationship 客户意向表
--循环增量导入
INSERT overwrite TABLE zx_dwd.dwd_fact_customer_relationship_apply PARTITION(dt)
select
 *
 from zx_ods.ods_customer_relationship_apply
 where dt='${TD_DATE}';

 --Employee 员工信息表
--覆盖导入
INSERT overwrite TABLE zx_dwd.dwd_dim_employee_apply
select
 *
 from zx_ods.ods_employee_apply;

--itcast_school 校区信息表
--覆盖导入
INSERT overwrite TABLE zx_dwd.dwd_dim_itcast_school_apply
select
 *
 from zx_ods.ods_itcast_school_apply;

 --itcast_subject 学科信息表
--覆盖导入
INSERT overwrite TABLE zx_dwd.dwd_dim_itcast_subject_apply
select
 *
 from zx_ods.ods_itcast_subject_apply;

--scrm_department 员工部门表
--覆盖导入
INSERT overwrite TABLE zx_dwd.dwd_dim_scrm_department_apply
select
 *
 from zx_ods.ods_scrm_department_apply;"
